package cn.kent.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 *
 */
@Configuration
public class RabbitMQConfig {
    public static final String HELLO_WORLD_QUEUE_NAME = "hello_world_queue";

    @Bean
    Queue queue1(){
        // 方法参数说明： 1.队列名 2.持久化 3.该队列是否具有排他性，有排他性的队列只能创建其的 Connection 处理 4.如果队列没有消费者，那么是否自动删除该队列
        return new Queue(HELLO_WORLD_QUEUE_NAME, true,false,false);
    }

}
